import request from "@/utils/request";
import { AxiosPromise } from "axios";

/**
 * 队列分页列表
 *
 */
export function getQueueList(){
	return request({
		url: '/api/v1/kafka/topicNames',
		method: 'get',
	});
}

/**
 * 开始消费
 *
 */
export function start(consumerId) {
	return request({
		url: '/api/v1/kafka/start/'+ consumerId,
		method: 'get'
	});
}

/**
 * 停止消费
 *
 */
export function stop(consumerId) {
	return request({
		url: '/api/v1/kafka/stop/'+ consumerId,
		method: 'get'
	});
}
